package cn.hcbycloud.stream.service.channel;


import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

/**
 * @author gaoh
 * @desc 输入信道
 * @date 2022年02月11日 下午 10:28
 */
@Component
public interface DefaultInputChannelProcessor {
    /**
     * 输入信道（需要与配置文件中的保持一致）
     */
    String DEFAULT_INPUT ="defaultInput";

    /**
     * 输入方法
     *
     * @return
     */
    @Input(DEFAULT_INPUT)
    SubscribableChannel defaultInput();
}